package com.niit

import com.niit.sparkConsumer.SparkConsumer

object Application {
    //正式程序入口
    def main(args: Array[String]): Unit = {
        SparkConsumer.getDataFromKafka()
    }
}
